package com.infinitus.autocatlog.service;


import java.util.List;
import java.util.Map;


import com.infinitus.autocatlog.domain.KafkaStartupLog;
import com.infinitus.autocatlog.domain.FilterCountLog;
import com.infinitus.autocatlog.domain.FilterLog;
import com.infinitus.autocatlog.domain.RecordItem;

public interface KafkaLogService {

	/**
	 * 保存过滤日志
	 * @param filterLog
	 */
	public void addFilterLog(FilterLog filterLog);

	/**
	 * 更新过滤统计
	 * @param countLog
	 */
	public void saveCountLog(FilterCountLog countLog);
	
	/**
	 * 保存数据(测试)
	 * @param recordItem
	 */
	@Deprecated
	public void saveLog(RecordItem recordItem);


	/**
	 * 查询页面初始化信息
	 * @return
	 */
	public Map<String, Object> loadLogInfo();

	/**
	 * 获取过滤统计
	 * @param params 参数
	 */
	public FilterCountLog getFilterCountLog(Map<String, Object> params);



	public List<FilterCountLog> findAllFilterLog();

	/**
	 * 启动标记日志(测试)
	 * @param startupLog
	 */
	public void addStartupLog(KafkaStartupLog startupLog);

	/**
	 * 记录更详细的过滤日志
	 * @param filterLog
	 */
	public void saveFilterLog(FilterLog filterLog);
}